package org.wejob;

public class Wejob {
    //public Main myThis=new Main();
    //0：初始化 1：观察者 2：执行者 3：Leader 4：关闭
    private int state = 1;
    private JobLeader leader;

    public void init(JobLeader leader) {

    }

    public void start(Configration configration) throws Exception {
        //连接zookeeper,获取主节点信息或者竞选为leader
        new ZkClient(configration.zkAddress)
                .start()
                .getLeaderAddress((leader) -> {
                    System.out.println(leader);
                });
        //创建leader代理对象
        //主节点存在时请求同步数据，接入集群；
        //初始换本地环境；
        //和主节点建立连接；

    }

    public JobLeader getLeader() throws Exception {
        return JobLeader.getInstance();
    }

}
